package com.hsgene.util.mq.rocket.annotation;

import org.springframework.stereotype.Component;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * 消息监听注解，用于定义监听的Topic和Tag
 *
 * @author wangbing
 * @version 1.0
 * @date 2019/1/16 13:36
 * Copyright: Copyright (c) 2019
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Component
public @interface RocketMQListener {

    /**
     * 监听的topic主题
     */
    String topic();

    /**
     * 监听的topic下的tag标签
     */
    String tag();
}
